package com.athui.utils.common.jdbc;

import com.athui.bean.config.ConnectInfo;
import org.apache.flink.annotation.PublicEvolving;

import java.sql.PreparedStatement;
import java.sql.SQLException;


/**
 * @description: TODO
 * @autor: zhangzhonghui
 * @create: 2024-08-06 17:55
 * @Version: 1.0
 */
@PublicEvolving
public interface JdbcStatementBuilder<T> {

    ConnectInfo buildConnectInfo();
    String buildSql();
    void accept(PreparedStatement ps,T t) throws SQLException;
}